package com.itany.time;


import com.alibaba.fastjson.JSON;
import com.itany.vo.TreeVo;
import com.itany.webstock.WebSocketConfig;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class OnlineNumbers implements  Runnable{
    @Override
    public void run() {
        while (true){
           try {
              Thread.sleep(300);
               List<TreeVo> list = new ArrayList<TreeVo>();
               for(WebSocketConfig cfg:WebSocketConfig.webSocketSet){
                   TreeVo vo =new TreeVo();
                   vo.setText(cfg.getUserName());
                   list.add(vo);
               }
               Map<String,Object> map = new HashMap<String,Object>();
               map.put("flag",2);
               map.put("msg",list);

               for(WebSocketConfig cfg:WebSocketConfig.webSocketSet){
                   cfg.getSession().getBasicRemote().sendText(JSON.toJSONString(map));
               }



           }catch (Exception e){
               e.printStackTrace();
           }

        }
    }
}
